package org.ala.tiktools.rpc.netty.attr;

import java.util.Map;
import java.util.concurrent.CompletableFuture;

import io.netty.util.AttributeKey;

/**
 * rpc相关的Attribute定义
 *
 * @author ala
 * @date 2025-04-08 13:11
 */
public class RpcAttribute {
    /**
     *  消息ackMapper
     *  <p> 在同一个channel内部，消息都是串行执行的
     */
    public static final AttributeKey<Map<Long, CompletableFuture<?>>> ackMapper = AttributeKey.valueOf("ackMapper");
}
